package cn.doitedu.eagle.names;

import cn.doitedu.eagle.beans.RuleKieSessionStateBean;
import org.apache.flink.api.common.state.MapStateDescriptor;

/**
 * @author 涛哥
 * @nick_name "deep as the sea"
 * @contact qq:657270652 wx:doit_edu
 * @site www.doitedu.cn
 * @date 2021-03-22
 * @desc 各类descriptor定义汇总
 */
public class StateDescriptors {

    static MapStateDescriptor<String, RuleKieSessionStateBean> ruleStateDesc;

    public static MapStateDescriptor<String, RuleKieSessionStateBean> getRuleStateDesc(){
        return new MapStateDescriptor<>("ruleStateDesc", String.class, RuleKieSessionStateBean.class);
    }


    static MapStateDescriptor<String, Integer> trigHitCountDesc;
    public  static MapStateDescriptor<String, Integer> getTrigHitCountDesc(){
        return new MapStateDescriptor<String, Integer>("trigHitCountDesc", String.class, Integer.class);
    }


    static MapStateDescriptor<String, String> ruleEventCountSqlDesc;
    public static MapStateDescriptor<String, String> getRuleEventCountSqlDesc(){
        return new MapStateDescriptor<String, String>("ruleEventCountSqlDesc", String.class, String.class);
    }


    static MapStateDescriptor<String, String> queryCountBuffStateDesc ;
    public static MapStateDescriptor<String, String> getQueryCountBuffStateDesc(){
        return new MapStateDescriptor<String, String>("queryCountBuffStateDesc", String.class, String.class);
    }



    static MapStateDescriptor<String, String> querySeqBuffStateDesc ;
    public static MapStateDescriptor<String, String> getQuerySeqBuffStateDesc(){
        return new MapStateDescriptor<String, String>("querySeqBuffStateDesc", String.class, String.class);
    }




}
